2716b68a7da1650f8bf9b6ab3e03749ea35751e2,src/test/java/com/ociweb/pronghorn/stage/RingBufferPipeline.java,DumpStageLowLevel,run,#,97
Before Change
while (Pipe.hasContentToRead(inputRing, msgSize)) {
Pipe.takeMsgIdx(inputRing);
Pipe.confirmLowLevelRead(inputRing, msgSize);
int meta = takeRingByteMetaData(inputRing);
int len = takeRingByteLen(inputRing);
After Change
while (Pipe.hasContentToRead(inputRing, msgSize)) {
if (Pipe.takeMsgIdx(inputRing)<0) {
Pipe.confirmLowLevelRead(inputRing, msgSize);
Pipe.releaseReadLock(inputRing);
requestShutdown();